/**
 * Copyright ©2016-2020 northkingbpo Corporation, All Rights Reserved
 * http://www.northkingbpo.net/
 */
package profile.hujia.spring.cloud.stream.kafka.server;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;

/**
 * class info
 *
 * @author hujia
 * @date 2019-03-26 14:53
 */
@EnableBinding({Sink.class})
@Slf4j
public class Consumer {
    @StreamListener(Sink.INPUT)
    public void receive(String message) {
        log.info(message);
    }
}
